package org.rency.mq.activemq.listener.failover.impl;

import org.rency.mq.activemq.jms.service.JmsAccessor;
import org.rency.mq.activemq.listener.failover.RetryExecutor;

public abstract class AbstractRetryExecutor implements RetryExecutor {
	private JmsAccessor mqAccessor;

	public JmsAccessor getMqAccessor() {
		if(mqAccessor == null){
			throw new IllegalArgumentException("MqAccessor can't be null.");
		}
		
		return mqAccessor;
	}

	public void setMqAccessor(JmsAccessor mqAccessor) {
		this.mqAccessor = mqAccessor;
	}


}
